package com.kafka.config;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

/**
 * @author syd
 * @create 2020-12-25 15:54
 */

@Configuration
@Data
public class KafkaConfig {
/*

    // 获取配置变量
    @Value("${kfk.host}")
    private String host;
    @Value("${kfk.port}")
    private String port;
    @Value("${kfk.user}")
    private String user;
    @Value("${kfk.password}")
    private String password;
    @Value("${kfk.schemaName}")
    private String schemaName;
    @Value("${kfk.batchSize}")
    private String batchSize;
    @Value("${kfk.topic_aids_static}")
    private String topicAidsStatic;
    @Value("${kfk.topic_aids_dynamic}")
    private String topicAidsDynamic;
    @Value("${kfk.topic_aids_water}")
    private String topicAidsWater;
*/

}
